//package com.sxt.websocket.controller;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.messaging.handler.annotation.MessageMapping;
//import org.springframework.messaging.handler.annotation.SendTo;
//import org.springframework.messaging.simp.SimpMessagingTemplate;
//import org.springframework.messaging.simp.annotation.SendToUser;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Controller;
//
//@Controller
//public class TopicController {
//
//    /*收到消息后广播推送*/
//    @MessageMapping("/boardcast")
//    @SendTo("/topic/boardcast")
//    public String sendtousers(String s){
//        System.out.println(s);
//        return "我是广播消息";
//    }
//
//    /*收到消息后精准投送到单个用户*/
//    @MessageMapping("/precise")
//    /*broadcast = false避免把消息推送到同一个帐号不同的session中*/
//    @SendToUser(value = "/topic/precise",broadcast = false)
//    public String sendtouser(String s){
//        System.out.println(s);
//        return "我是精准投送消息";
//    }
//
//
//    private SimpMessagingTemplate template;
//    @Autowired
//    public TopicController (SimpMessagingTemplate template) {
//        this.template = template;
//    }
//    /*下面2个是不用接收消息动态发送消息的方法*/
//    /*Scheduled为定时任务，演示*/
//    @Scheduled(fixedDelay = 1500)
//    public void boardcast(){
//        this.template.convertAndSend("/topic", "来自服务器广播消息");
//    }
//
//    @Scheduled(fixedDelay = 1500)
//    public void precise(){
//        this.template.convertAndSendToUser("abc", "/message","来自服务器精准投送消息");
//    }
//
//}
